package com.xframe.event.bus.core.msg;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
/**
 * 消息接收器接口
 *
 * @author xufeng
 * @version 1.0
 * @date 2022-09-19
 */
public interface IReceiveMsg {

    /**
     * 获得当前的通道
     * */
    Channel getCurChannel();

    /**
     * 消息处理器
     * */
    IMsgProc getMsgProc();
    /**
     * 连接对象
     * */
    Connection getMsgConn();
    /**
     * 处理消息个数的参数
     * */
    int getQos();
    /**
     * 是否自动确认
     * */
    boolean isAutoAck();
    /**
     * 初始化函数
     * */
    void init();
}
